/**
 * 
 * 配置mysql
 * 
 */
const mysql = require('mysql');
const { MYSQL_CONFIG } = require('../config/db');

// 1.获取连接
const con = mysql.createConnection(MYSQL_CONFIG);

// 2.连接数据库
con.connect();

// 3.统一执行sql 的函数(给外部传sql)
function exec(sql) {
    const promise = new Promise((resolve, reject) => {
        // 执行sql
        con.query(sql, (err, result) => {
            if (err) { // 发生错误
                reject(err)
                return;
            } 
            resolve(result)
        })
    })
    return promise;
}

module.exports = {
    exec
}
